package com.xiguthings.xiniu.iot.postproducer.worker.producer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ProcduceMessageCenter {
    private final Logger LOGGER = LoggerFactory.getLogger(ProcduceMessageCenter.class);

    @Autowired
    private HandleThreadPool handleThreadPool;

    /**
     * 更具设备数据，生产postData
     *
     * @param deviceDataStr
     * @return 如果是null则不需要发送post
     */
    public void procduceMessage(String deviceDataStr) {
        handleThreadPool.execute(deviceDataStr);
    }


}
